package jucTest;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * 测试blockingqueue方法 add  remove  element
 */
public class BlockQueueDemo {
//    public static void main(String[] args) {
//        ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(5);
//        queue.add("1");
//        System.out.println(queue.element());
//        queue.add("2");
//        queue.add("3");
//        queue.add("4");
//        System.out.println(queue.element());
//        queue.add("5");
//        //queue.add("6");
//        queue.remove();
//        queue.remove();
//        queue.remove();
//        queue.remove();
//        System.out.println(queue.element());
//        queue.remove();
//        //queue.remove();
//       // System.out.println(queue.element());
//    }

    /**
     * 测试blockingqueue方法 offer  poll  peek
     * @param args
     */
   /* public static void main(String[] args) {
       ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(5);
        queue.offer("1");
        System.out.println(queue.peek());
        queue.offer("2");
        queue.offer("3");
        queue.offer("4");
        System.out.println(queue.peek());
        queue.offer("5");
        queue.offer("6");
        queue.poll();
        queue.poll();
        queue.poll();
        queue.poll();
        System.out.println(queue.peek());
        queue.poll();
        queue.poll();
       // System.out.println(queue.peek());
    }*/

    /**
     *阻塞 put() take()
     * @param args
     */
      public static void main(String[] args) throws InterruptedException {
       ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(5);
        queue.put("1");
        queue.put("2");
        queue.put("3");
        queue.put("4");
        queue.put("5");
        queue.put("6");
    }
}
